package com.ccp.dev.im.server.proxy;

import com.ccp.dev.im.server.model.MessageWrapper;
import com.ccp.dev.im.server.model.proto.MessageProto;

public interface MessageProxy {

    MessageWrapper convertToMessageWrapper(String sessionId, MessageProto.Model message);
    /**
     * 保存消息
     * @param message
     */
    String saveMessageToDB(MessageWrapper message);
    /**
     * 更新上线隐身状态
     * @param sessionId
     * @param status
     */
    void updateOnlineStatusToDB(String sessionId , String status);
    /**
     * 获取上线状态消息
     * @param sessionId
     * @return
     */
    MessageProto.Model  getOnLineStateMsg(String sessionId);
    /**
     * 重连状态消息
     * @param sessionId
     * @return
     */
    MessageWrapper  getReConnectionStateMsg(String sessionId);
    
    /**
     * 获取下线状态消息
     * @param sessionId
     * @return
     */
    MessageProto.Model  getOffLineStateMsg(String sessionId);
}

